package com.cold.demo.rabbitmq.demo3;

import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;

/**
 * @author: zyc
 */
@Component

public class AMQListener$1 {


    @RabbitListener(queuesToDeclare = { @Queue(name = "test1") })
    public void process(String msg) throws InterruptedException {
        System.out.println("收到消息：" + msg);
        Thread.sleep(1000);
        throw new IllegalArgumentException("处理失败");
    }
}
